package com.xxx.nio.server;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;

@ChannelHandler.Sharable  // 这个注解是为了线程安全
public class EchoServerHandler extends ChannelInboundHandlerAdapter {

    // 当 Channel 注册到 EventLoop 时被调用
    @Override
    public void channelRegistered(ChannelHandlerContext ctx) {
        System.out.println("Channel registered");
    }

    // 当Channel被激活（建立连接）时被调用
    @Override
    public void channelActive(ChannelHandlerContext ctx) {
        System.out.println("Channel active");
    }

    // 读取数据时被调用
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 将客户端传入的消息转换为Netty的ByteBuf类型
        ByteBuf in = (ByteBuf) msg;
        String msg1 = in.toString(CharsetUtil.UTF_8);
        System.out.println("Server收到消息：" + msg1);
        ctx.write(Unpooled.copiedBuffer(msg1 + " ack from server", CharsetUtil.UTF_8)); // 将接收到的消息写回发送者
    }

    // 数据读取完成时被调用
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.flush(); // 待所有写入完成后，将数据刷出
//        // 将未处决消息冲刷到远程节点， 并且关闭该Channel
//        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER)
//                .addListener(ChannelFutureListener.CLOSE);
    }

    // 发生异常时被调用
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();  // 发生异常关闭连接
    }

    // 当 Channel 从 EventLoop 注销时被调用
    @Override
    public void channelUnregistered(ChannelHandlerContext ctx) {
        System.out.println("Channel unregistered");
    }
}